package com.t2t.top.framework.rocketmq.client.extension;

import com.alibaba.rocketmq.common.message.MessageExt;

import java.io.Serializable;

/**
 * 扩展MessageConsumer类
 */
public abstract class MessageExtConsumer<E extends Serializable> implements MessageConsumer<E> {

    public abstract void consume(MessageExt msgExt, E messageObject) throws Exception;

    public void consume(E messageObject) throws Exception {
    }

}